package com.xuecheng.content.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.ThreadPoolExecutor;

/**
 * @author Sober_wxy
 * @date 2022/7/23 17:08
 */
@Configuration
public class ThreadPoolConfig {

        /**
         * 线程池配置
         * @return 线程对象
         */
        @Bean("xueChengPool")
        public ThreadPoolTaskExecutor executor(){

                ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
                //核销线程数
                taskExecutor.setCorePoolSize(2);
                //线程池维护线程的最大数量,只有在缓冲队列满了之后才会申请超过核心线程数的线程
                taskExecutor.setMaxPoolSize(10);
                //缓存队列
                taskExecutor.setQueueCapacity(50);
                //允许的空闲时间,当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
                taskExecutor.setKeepAliveSeconds(200);
                //异步方法内部线程名称
                taskExecutor.setThreadNamePrefix("asyncThread-");
                /**
                 * 当线程池的任务缓存队列已满并且线程池中的线程数目达到maximumPoolSize，如果还有任务到来就会采取任务拒绝策略
                 * 通常有以下四种策略：
                 * ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
                 * ThreadPoolExecutor.DiscardPolicy：也是丢弃任务，但是不抛出异常。
                 * ThreadPoolExecutor.DiscardOldestPolicy：丢弃队列最前面的任务，然后重新尝试执行任务（重复此过程）
                 * ThreadPoolExecutor.CallerRunsPolicy：重试添加当前的任务，自动重复调用 execute() 方法，直到成功
                 */
                taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
                taskExecutor.initialize();
                return taskExecutor;

        }

}
